package jobs.poc;

import java.io.IOException;

import jobs.poc.writables.WordPairDecade;
import jobs.poc.writables.WordPairDecadeTimes;

import org.apache.hadoop.io.Text;
import org.apache.hadoop.mapreduce.Reducer;


public class sumReducer extends Reducer<WordPairDecade, WordPairDecadeTimes,Text,Text> {

	protected void reduce(WordPairDecade key,
			Iterable<WordPairDecadeTimes> values,
			Context context)
			throws IOException, InterruptedException {
		for(WordPairDecadeTimes val: values){
			context.write(new Text(key.toString()), new Text(val.toString()));
		}
	}
	
	
	

	

}
